package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.DistributorBinderConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

/**
 * distributor 消息队列
 * @author 魏荣杰
 * @date 2019/2/22 18:48
 * @since v1.0
 * @version v1.0
 */
@Service("distributorProducerBinder")
public interface DistributorProducerBinder {
    /**
     * 经销商
     */
    @Output(DistributorBinderConstant.DISTRIBUTOR_OUTPUT)
    MessageChannel distributorOutput();

    @Output(DistributorBinderConstant.DISTRIBUTOR_HANDOVER_OUTPUT)
    MessageChannel distributorHandoverOutput();

    @Output(DistributorBinderConstant.DISTRIBUTOR_COMMUNICATE_OUTPUT)
    MessageChannel distributorCommunicateOutput();

    @Output(DistributorBinderConstant.DISTRIBUTOR_CONTACT_OUTPUT)
    MessageChannel distributorContactOutput();
}
